package Dao;

import Modelo.Chofer;
import Modelo.ClassConexionDAO;
import Modelo.Validaciones;
import PackageConeccion.ConeccionBD;
import java.sql.ResultSet;
import java.sql.SQLException;

public class DaoChofer extends ClassConexionDAO
{
    public void IncluirChofer(Chofer chofer)
  {
     String Sql;     
     
     Sql="INSERT INTO chofer (cedula, nombres, direccion, telefono,";
     Sql=Sql+"ci_socio,codigo_coop) VALUES ("; 
     
    Sql=Sql+Validaciones.Apost(chofer.getCedula())+",";    
    Sql=Sql+Validaciones.Apost(chofer.getNombres())+",";            
    Sql=Sql+Validaciones.Apost(chofer.getDireccion())+",";
    Sql=Sql+Validaciones.Apost(chofer.getTelefonos())+",";
    Sql=Sql+Validaciones.Apost(chofer.getCISocio())+",";
    Sql=Sql+Validaciones.Apost(chofer.getCodCoop())+")";
    
    ConeccionBD.ejecutar(Sql);
  }
        
  public void ModificarChofer(Chofer chofer)
  {
     String Sql;
      
    Sql="UPDATE chofer SET ";
    Sql=Sql+"nombres="+Validaciones.Apost(chofer.getNombres())+",";
    Sql=Sql+"direccion="+Validaciones.Apost(chofer.getDireccion())+",";            
    Sql=Sql+"telefono="+Validaciones.Apost(chofer.getTelefonos()); 
            
    Sql=Sql+" WHERE cedula="+ Validaciones.Apost(chofer.getCedula());  
    ConeccionBD.ejecutar(Sql);
  }   
//------------------------------  
  public ResultSet BuscarChofer(String Cedula)
  {
     ResultSet registroChofer; 
     String Sql;
     Sql="SELECT * FROM chofer WHERE cedula="+Validaciones.Apost((Cedula));
     registroChofer=ConeccionBD.consultar(Sql);
     return registroChofer;
  }
//-------------------------  

  public ResultSet ConsultarChofer()
  {
     ResultSet registroChofer; 
     String Sql;
     
     Sql="SELECT * FROM chofer"; 
     registroChofer=ConeccionBD.consultar(Sql);
     
     return registroChofer;
      
  }   

  public Integer CantidadChoferes() throws SQLException
  {
      ResultSet cant;
      String sql;
      
      sql="SELECT count(cedula) As Total from chofer";
      cant = ConeccionBD.consultar(sql);
      if (cant.next())      
        return cant.getInt("Total");
      else
        return 0;  
  }
  //------------------------------
 /* public Integer CantidadChofSocio(String cedSocio) throws SQLException
  {
      ResultSet cant;
      String sql;
      
      sql="SELECT count(cedula) As Total from chofer WHERE ci_socio="+Validaciones.Apost(cedSocio);
      cant = ConeccionBD.consultar(sql);

      if (cant.next())      
        return cant.getInt("Total");
      else
        return 0;  

  }*/
  //-------------------------
  public ResultSet BuscarChoferesSocio(String CedSocio)
  {
     ResultSet registroChofer; 
     String Sql;
     
     Sql="SELECT * FROM chofer WHERE ci_socio="+Validaciones.Apost(CedSocio);
     registroChofer=ConeccionBD.consultar(Sql);
     return registroChofer;
  }
  public ResultSet CantidadChofSocio(String cedSocio)
  {
      ResultSet cant;
      String sql;
      
      sql="SELECT count(*) from chofer WHERE ci_socio="+Validaciones.Apost(cedSocio);
      cant = ConeccionBD.consultar(sql);
      return cant;
  }
//------------------------------  
}